package cn.tedu.charging.order;

import com.rabbitmq.client.DeliverCallback;
import com.rabbitmq.client.Delivery;

import java.io.IOException;

public class RabbitConsumer implements DeliverCallback {
    @Override
    public void handle(String consumerTag, Delivery message) throws IOException {
        String msg = new String(message.getBody());
        System.out.println("收到消息：" + msg);
    }
}
